package com.tm.test;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

/**
 * @author Rocky
 * @create 2022-10-11 18:43
 * 单向发送
 * 发送方只负责发送消息，不等待服务端的回调触发，只管发，不管收。耗时极短。
 * 应用场景：适用于耗时短，且对可靠性、回调要求不高的场景，例如：日志记录。
 */
public class RocketMQTest3 {
    //单向消息
    public static void main(String[] args) throws Exception {
        //创建producer对象
        DefaultMQProducer producer = new DefaultMQProducer("tmGoodsGroup");
        //连接nameServer
        producer.setNamesrvAddr("192.168.0.3:9876");
        //启动
        producer.start();
        String a = "{'goodsId':5432,'goodsName':'纽曼34','goodsPrice':'889'}";
        //创建消息对象
        Message message = new Message("goods111","goodsUpdate",a.getBytes());
        //进行发送单向消息
        producer.sendOneway(message);
        //关闭producer
        producer.shutdown();
    }

}
